//package com.culture.bootdemo.mq.kafka;
//
//import lombok.extern.slf4j.Slf4j;
//import org.apache.kafka.clients.producer.ProducerRecord;
//import org.springframework.beans.factory.annotation.Autowired;
//import org.springframework.kafka.core.KafkaTemplate;
//import org.springframework.kafka.support.SendResult;
//import org.springframework.stereotype.Component;
//import org.springframework.util.concurrent.ListenableFutureCallback;
//
//
///**
// * @Author: wenjl
// * @Date: 2021/6/10 15:15
// * @Description:
// */
//@Component
//@Slf4j
//public class DemoKafkaProducer {
//
//    @Autowired
//    private KafkaTemplate<String, String> kafkaTemplate;
//
//    public void sendMessage(){
//        ProducerRecord<String, String> producerRecord = new ProducerRecord<>("topic", "11");
//        kafkaTemplate.send(producerRecord);
//        //或者使用同步方法
//        try {
//            kafkaTemplate.send(producerRecord).get();
//        } catch (Exception e) {
//            e.printStackTrace();
//        }
//
//        kafkaTemplate.send("topic","msg对象");
//
//        kafkaTemplate.send("ioc-auto-contact", "msg对象").addCallback(new KafkaFutureCallback());
//
//    }
//
//    private static class KafkaFutureCallback implements ListenableFutureCallback<SendResult> {
//
//        @Override
//        public void onFailure(Throwable ex) {
//            log.error("send kafka failed: {}", ex);
//        }
//
//        @Override
//        public void onSuccess(SendResult result) {
//            log.info("send kafka success: {}", result.getProducerRecord());
//        }
//    }
//
//}
